package main

import (
	"log"

	"github.com/streadway/amqp"
)

func main() {
	// 连接到RabbitMQ服务器
	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
	if err != nil {
		log.Fatal(err)
	}
	defer conn.Close()

	// 创建一个频道
	ch, err := conn.Channel()
	if err != nil {
		log.Fatal(err)
	}
	defer ch.Close()

	// 声明队列（单聊）
	q, err := ch.QueueDeclare(
		"chat", // 队列名称
		false,  // 是否持久化
		false,  // 是否自动删除
		false,  // 是否独占
		false,  // 是否等待消费者
		nil,    // 额外参数
	)
	if err != nil {
		log.Fatal(err)
	}

	// 发送消息到队列
	body := "Hello, this is a single chat message!"
	err = ch.Publish(
		"",     // 默认交换机
		q.Name, // 路由键（队列名称）
		false,  // 是否持久化
		false,  // 是否确认
		amqp.Publishing{
			ContentType: "text/plain",
			Body:        []byte(body),
		},
	)
	if err != nil {
		log.Fatal(err)
	}

	log.Printf(" [x] Sent %s", body)
}
